package com.java.netty.nio.netty.inboundhandlerandoutboundhandler;

import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

/**
 * @Author: Dgg
 * @Date: 2022/1/23 17:56
 */

public class MyClinetHandler extends SimpleChannelInboundHandler<Long> {
	@Override
	protected void channelRead0(ChannelHandlerContext ctx, Long msg) throws Exception {

		System.out.println("得到服务器的信息：" + ctx.channel().remoteAddress());
		System.out.println("msg= " + msg);
	}

	@Override
	public void channelActive(ChannelHandlerContext ctx) throws Exception {
		System.out.println("MyClientHandler 发送数据");
//		ctx.writeAndFlush(Unpooled.compositeBuffer());
		ctx.writeAndFlush(123456L);//发送一个long 数据
		/**
		 *  在这里 如果发送类型和定义类型不一样就会在 编码的时候跳过 encoder 直接发送数据
		 */
//		ctx.writeAndFlush(Unpooled.copiedBuffer("abcdabcdabcd", CharsetUtil.UTF_8));
	}
}
